const mysql = require('mysql')
//引入连接数据库的配置信息
const db_config = require('../db/db')

//创建数据库连接池
let Myconnect = null;

//开始连接数据库
function openMysql(){
	Myconnect = mysql.createConnection(db_config)
    Myconnect.connect(function (err) {
        if (err) {
            console.log(`myqsl连接失败:${err}!`)
        } else {
            console.log('恭喜哦，mysql连接成功哦')
        }
    })
}

// 查询完关闭数据库
function closeMysql(Myconnect) {
	Myconnect.end((err) => {
		if (err) {
			console.log(`mysql关闭失败:${err}!`)
		} else {
			console.log('mysql关闭成功')
		}
	})
}

exports.getDeviceDemo = (req,res) => {
    //query() 函数用于mysql语句查询
    openMysql()
    let sql = 'select * from device_demo'
	Myconnect.query(sql, function(err, result) {
		if (err) {
			res.send('fullfild')
		} else {
			let resMsg = JSON.parse(JSON.stringify(result))
			closeMysql(Myconnect)  //调用函数关闭mysql连接
			res.send(resMsg)
		}
	});
}

exports.getGroupDemo = (req,res) => {
    //query() 函数用于mysql语句查询
    openMysql()
    let sql = 'select * from group_demo'
	Myconnect.query(sql, function(err, result) {
		if (err) {
			res.send('fullfild')
		} else {
			let resMsg = JSON.parse(JSON.stringify(result))
			closeMysql(Myconnect)  //调用函数关闭mysql连接
			res.send(resMsg)
		}
	});
}